package com.mall.hadoop.format;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;

import com.mall.untils.DateUtils;

/**
 * 重写自定义MultipleOutputFormat类的AlphabetOutputForma方法
 * 得到自定义文件名
 * @author tgy
 *
 */
public class AlphabetOutputFormat extends MultipleOutputFormat<Text, IntWritable>{
	
	@Override
	protected String generateFileNameForKeyValue(Text key, IntWritable value, Configuration conf) {
		//写业务逻辑，可以输出不少于0个文件
		String k = key.toString();
		if(k.contains("p")||k.contains("c")||k.contains("a")){
			//园所统计文件
			return "school_"+DateUtils.getDateFormat("yyyyMMdd")+".txt";
		}
		if(k.contains("sf")||k.contains("sh")||k.contains("sq")){
			//八大能力统计文件
			return "review_"+DateUtils.getDateFormat("yyyyMMdd")+".txt";
		}
		return "info.txt";
	}

}
